<?php
declare (strict_types=1);

namespace app\command\install;

use app\exception\BaseException;
use think\facade\Db;


class Fuc
{
    /**
     * @param $filePath       数据库文件路径
     * @param $force          是否需要重新链接  【如果是重新安装必须重连，否则使用的是旧的配置】
     * @throws BaseException
     */
    static public function initSql($filePath)
    {
        try {
            if (!file_exists($filePath)) {
                throw new BaseException('数据库文件不存在');
            }
            $sql = file_get_contents($filePath);

            //连接install命令中指定的数据库\
            $instance = Db::connect();
            $instance->execute("SELECT 1");     //如果是【数据】增删改查直接运行
            $instance->getPdo()->exec($sql);    //如果是【数据表】的增删查改，需要通过excute或query获取pdo实例，在执行exec。这里必须是exec
        } catch (\Exception $e) {
            throw new BaseException($e->getMessage());
        }
    }
}